package com.cw.realtime.dim
package function

import com.cw.realtime.common.util.HbaseUtil
import io.circe.parser

object HbaseTest {
  def main(args: Array[String]): Unit = {

    for {
      conn <- HbaseUtil.getConnection
      json <-  parser.parse("""  {"name":"li hua", "age":"18" }  """)

    }{

      HbaseUtil.createTable(conn, "test","foo", "info")
      HbaseUtil.putCells(conn, "test", "foo", "1", "info", json)
      HbaseUtil.closeConnection(Option(conn))
    }



  }

}
